
#include "model/PublisherNode.h"

namespace zeroplus::mq
{
    ssize_t PublisherNode::Send(const std::string topic, const Bytes &message)
    {
        zmqpp::message_t zmqMessage;
        zmqMessage << topic << message.to_string();
        ssize_t size = conn_->WriteMsg(zmqMessage);
        return size;
    }

}
